#pragma once

class ZeroMQSubscriber
{
public:
    ZeroMQSubscriber();
    ~ZeroMQSubscriber();

public:
    bool initialize(const char *address);
    int  recv(char *buf, int maxLen);

private:
    void *m_zmqContext;
    void *m_zmqSocket;
};